アカウントのデフォルトのイベントテーブルにログを取得する #SnowflakeDB

--アカウントのイベントテーブルを確認
SHOW PARAMETERS LIKE 'event_table' IN ACCOUNT;

>SHOW PARAMETERS LIKE 'event_table' IN ACCOUNT;
+-------------+----------------------------+----------------------------+-------+-----------------------------------------+--------+
| key         | value                      | default                    | level | description                             | type   |
|-------------+----------------------------+----------------------------+-------+-----------------------------------------+--------|
| EVENT_TABLE | snowflake.telemetry.events | snowflake.telemetry.events |       | Event destination for the given target. | STRING |
+-------------+----------------------------+----------------------------+-------+-----------------------------------------+--------+

--アカウントのアクティブな任意のイベントテーブルを設定
ALTER ACCOUNT SET EVENT_TABLE = my_database.my_schema.my_events;

--ログレベルの設定ロールを作成
--accountレベルのログ設定権限とデータベースレベルの場合はそのModify権限が必要
USE ROLE USERADMIN;
CREATE OR REPLACE ROLE log_admin;
GRANT ROLE log_admin TO ROLE SYSADMIN;

USE ROLE ACCOUNTADMIN;
GRANT MODIFY LOG LEVEL ON ACCOUNT TO ROLE log_admin;

USE ROLE SECURITYADMIN;
GRANT MODIFY ON DATABASE <対象のデータベース> TO ROLE log_admin;

USE ROLE ACCOUNTADMIN;
GRANT APPLICATION ROLE SNOWFLAKE.EVENTS_VIEWER TO ROLE log_admin;

USE ROLE SYSADMIN;

--アカウントのイベントテーブルを確認：デフォルトは snowflake.telemetry.events
SHOW PARAMETERS LIKE 'event_table' IN ACCOUNT;

--アカウントレベルのログレベルの設定を確認：デフォルトはNONE
SHOW PARAMETERS LIKE 'log_level' IN ACCOUNT;

USE ROLE SYSADMIN;

--ログの取得先とするデータベースを作成
CREATE OR REPLACE DATABASE TELEMETRY_TEST_DB;
USE SCHEMA TELEMETRY_TEST_DB.PUBLIC;

--サンプルテーブルを作成
CREATE OR REPLACE TABLE parent (ID INTEGER);
CREATE OR REPLACE TABLE child (ID INTEGER);

--Snowflakeスクリプトでストアドプロシージャを定義
CREATE OR REPLACE PROCEDURE insert_data()
RETURNS VARCHAR NOT NULL
LANGUAGE SQL
AS
$$
BEGIN
    BEGIN TRANSACTION;
    INSERT INTO telemetry_test_db.public.parent VALUES (1);
    SELECT 1/0; --エラーを発生させる
    INSERT INTO telemetry_test_db.public.child VALUES (1);
    COMMIT;
    RETURN 'complete';
EXCEPTION
  WHEN OTHER THEN
  ROLLBACK;
  RAISE;
END;
$$
;

--プロシージャを実行
>call insert_data();
100051 (22012): Uncaught exception of type 'STATEMENT_ERROR' on line 5 at position 4 : Division by zero

USE ROLE ACCOUNTADMIN;
SELECT * FROM SNOWFLAKE.TELEMETRY.EVENTS ORDER BY TIMESTAMP DESC;

--ログレベルの設定ロールを作成
--accountレベルのログ設定とデータベースレベルの場合はそのModifyが必要
USE ROLE USERADMIN;
CREATE OR REPLACE ROLE log_admin;
GRANT ROLE log_admin TO ROLE SYSADMIN;

USE ROLE ACCOUNTADMIN;
GRANT MODIFY LOG LEVEL ON ACCOUNT TO ROLE log_admin;

USE ROLE SECURITYADMIN;
GRANT MODIFY ON DATABASE TELEMETRY_TEST_DB TO ROLE log_admin;

--showコマンドを実行するためにデータベースへのusageを付与
GRANT USAGE ON DATABASE TELEMETRY_TEST_DB TO ROLE log_admin;

--データベースレベルで LOG LEVLE を設定する
USE ROLE log_admin;
--確認
SHOW PARAMETERS LIKE '%LOG_LEVEL%' IN DATABASE TELEMETRY_TEST_DB;

--ログレベルを「WARN」に設定
ALTER DATABASE TELEMETRY_TEST_DB SET LOG_LEVEL = WARN;
SHOW PARAMETERS LIKE '%LOG_LEVEL%' IN DATABASE TELEMETRY_TEST_DB;

>SHOW PARAMETERS LIKE '%LOG_LEVEL%' IN DATABASE TELEMETRY_TEST_DB;
+-----------+-------+---------+----------+----------------------------------------+--------+
| key       | value | default | level    | description                            | type   |
|-----------+-------+---------+----------+----------------------------------------+--------|
| LOG_LEVEL | WARN  | OFF     | DATABASE | LOG_LEVEL to use when filtering events | STRING |
+-----------+-------+---------+----------+----------------------------------------+--------+
1 Row(s) produced. Time Elapsed: 0.130s

--再度プロシージャを実行
USE ROLE SYSADMIN;
USE SCHEMA TELEMETRY_TEST_DB.PUBLIC;
call insert_data();

--1分程経過したらイベントテーブルをクエリ
USE ROLE ACCOUNTADMIN;
SELECT * FROM SNOWFLAKE.TELEMETRY.EVENTS ORDER BY TIMESTAMP DESC;

{
  "db.user": "<ユーザー>",
  "snow.database.id": 61,
  "snow.database.name": "TELEMETRY_TEST_DB",
  "snow.executable.id": 613,
  "snow.executable.name": "INSERT_DATA():VARCHAR(16777216)",
  "snow.executable.type": "PROCEDURE",
  "snow.owner.id": 4,
  "snow.owner.name": "SYSADMIN",
  "snow.query.id": "01b8e892-0001-fb39-0001-f082000871ea",
  "snow.schema.id": 92,
  "snow.schema.name": "PUBLIC",
  "snow.session.id": 545916113682718,
  "snow.session.role.primary.id": 4,
  "snow.session.role.primary.name": "SYSADMIN",
  "snow.user.id": 1,
  "snow.warehouse.id": 4,
  "snow.warehouse.name": "COMPUTE_WH",
  "telemetry.sdk.language": "sql"
}

{
  "exception.escaped": true,
  "exception.message": "Uncaught exception of type 'STATEMENT_ERROR' on line 5 at position 4 : Division by zero",
  "exception.type": "100051"
}

--イベントテーブル閲覧用の権限を付与
USE ROLE ACCOUNTADMIN;
GRANT APPLICATION ROLE SNOWFLAKE.EVENTS_VIEWER TO ROLE log_admin;

--イベントテーブルビューをクエリできるようになる
USE ROLE log_admin;
SELECT * FROM SNOWFLAKE.TELEMETRY.EVENTS_VIEW ORDER BY TIMESTAMP DESC;